package com.hd123.wsw.activemq.producer.queue;

import javax.annotation.Resource;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;

/**
 * 
 * @author wushanwen
 * @description 队列消息生产者，发送消息到队列
 * 
 */
@Component("queueSender")
public class QueueSender {
  @Resource(name = "jmsQueueTemplate")
  private JmsTemplate jmsTemplate;// 通过@Qualifier修饰符来注入对应的bean

  /**
   * 发送一条消息到指定的队列（目标）
   * 
   * @param queueName
   *          队列名称
   * @param message
   *          消息内容
   */
  public void send(String queueName, final String message) {
    jmsTemplate.send(queueName, new MessageCreator() {
      @Override
      public Message createMessage(Session session) throws JMSException {
        return session.createTextMessage(message);
      }
    });
  }

}
